# -*- coding: utf-8 -*-
import time
from celery import shared_task
from celery.utils.log import get_task_logger
from flask import g

logger = get_task_logger(__name__)


@shared_task
def async_health(current_time, **kwargs):
    logger.info(f'{__name__}')
    logger.info('这是日志信息')
    # time.sleep(5)
    return f'Celery Running well, Task Result {current_time} 上下文：{g.name}'
